package com.taobao.txc.a.b;

import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import java.util.concurrent.ConcurrentHashMap;

class r
  implements ChannelFutureListener
{
  r(p paramp, u paramu) {}
  
  public void a(ChannelFuture paramChannelFuture)
  {
    if (!paramChannelFuture.isSuccess())
    {
      b localb = (b)this.b.n.remove(Long.valueOf(this.a.e()));
      if (localb != null) {
        localb.a(paramChannelFuture.cause());
      }
      paramChannelFuture.channel().close();
    }
  }
}


/* Location:           C:\Users\ibm\Downloads\txc-yun-sample (1)\txc-yun-sample\lib\txc-client-2.0.72.jar
 * Qualified Name:     com.taobao.txc.a.b.r
 * JD-Core Version:    0.7.0.1
 */